package com.celeritymq.server.servers;

import java.io.Serializable;
import java.rmi.Remote;
import java.rmi.RemoteException;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

import com.celeritymq.consumer.CelerityQueueReceiver;
import com.celeritymq.consumer.CelerityTopicSubscriber;
import com.celeritymq.destination.CelerityTopic;

public interface ConsumerAcceptor extends Remote,Serializable{
	
	//将topic接收者者加入管理名单
	void addToTopicSubscriberMap(CelerityTopicSubscriber topicSubscriber)throws RemoteException;
	//将queue接收者加入管理名单
	void addToQueueReceiverMap(CelerityQueueReceiver queueReceiver)throws RemoteException;
	//设定该Acceptor要将消息传送到的topic Manager
	void setTopicManager(TopicManager topicManager);
	//设定该Acceptor要将消息传送到的queue Manager
	void setQueueManager(QueueManager queueManager);
	
}
